package com.yuezhi.consumer.constant;

public class QueueConstant {

    public static final String HELLO_QUEUE = "hello-queue";

    public static final String YUE_ZHI_QUEUE = "yue-zhi-queue";

    /*=========== direct ===============*/
    public static final String DIRECT_QUEUE = "direct-queue";

    public static final String DIRECT_EXCHANGE = "direct-exchange";

    /*=========== fanout ===============*/
    public static final String FANOUT_QUEUE_ONE = "fanout-queue-one";

    public static final String FANOUT_QUEUE_TWO = "fanout-queue-two";

    public static final String FANOUT_EXCHANGE = "fanout-exchange";

    /*=========== topic ===============*/
    public static final String TOPIC_QUEUE_ONE = "topic-queue-one";

    public static final String TOPIC_QUEUE_TWO = "topic-queue-two";

    public static final String TOPIC_QUEUE_THREE = "topic-queue-three";

    public static final String TOPIC_EXCHANGE = "topic-exchange";

    /*=========== header ===============*/
    public static final String HEADER_QUEUE_ONE = "header-queue-one";

    public static final String HEADER_QUEUE_TWO = "header-queue-two";

    public static final String HEADER_EXCHANGE = "header-exchange";


    /*===================  RPC  ==============================*/
    public static final String RPC_QUEUE_ONE = "rpc-queue-one";

    public static final String RPC_QUEUE_TWO = "rpc-queue-two";

    public static final String RPC_EXCHANGE = "rpc-exchange";

    /*=================== 死信队列 ===========================*/

    public static final String DLX_RECEIVE_QUEUE = "dlx_receive_queue";

    public static final String DLX_RECEIVE_EXCHANGE = "dlx_receive_exchange";

    public static final String DLX_ROUTE_KEY = "dlx-route";
}
